from celery import Celery


"""
Celery的作用：
将
生产者
生产者需要单独创建一个包，包中的文件必须以tasks.py命名
生产者本质是一个函数
这个函数必须要经过celery的实例对象的task装饰器来装饰
这个任务需要让celery自动检测

消息队列

消费者
指令：celery -A proj worker -l info
     celery -A celery实例对象的文件 worker -l info
     需要在虚拟环境中执行celery -A celery_tasks.main worker -l info
串联起来
"""

import os
# 让celery去加载有可能用到的django的配置文件
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings")


# 创建Celery实例对象

app = Celery('celery_tasks')

# 配置 消息队列

# 让celery加载配置信息
app.config_from_object('celery_tasks.config')

# 让celery自动检测
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])